package netty.queue;

import com.lmax.disruptor.EventHandler;
import netty.tcp.TCPClient;

class StringEventHandler implements EventHandler<ZetasEvent> {

    TCPClient tcpClient;

    public StringEventHandler(TCPClient tcpClient) {
        this.tcpClient = tcpClient;
    }

    public void onEvent(ZetasEvent event, long sequence, boolean endOfBatch) throws Exception {
//        tcpClient.sendMsg(event.getTime(), null, endOfBatch);
    }
}

